package com.example.websocket.redis.queue;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.stereotype.Component;

//@Component
public class QueueTestListener implements RedisDelayedQueueListener<String> {

	private static final Logger LOGGER = LogManager.getLogger(QueueTestListener.class);
	
	@Override
	public void invoke(String t) {
		LOGGER.info("Listen queue SendInvoiceEmailListener, Get value:{}", t);
		System.out.println(t);
	}

}
